# -*- coding=utf-8 -*-


def get_rtn_dict(db_engine):
    sql = "SELECT rtns,bezeichnung FROM Als_rc.prozessketten WHERE rownum<=50"
    result = db_engine.execute(sql)
    rtn_dict = {}
    for row in result:
        if row['rtns'].find(',') < 0:
            rtn_dict[row['rtns']] = row['bezeichnung']
    return rtn_dict
